package scheduler

import (
	"gitee.com/fierce_wolf/go-fox-edge-common/commMqtt"
	"gitee.com/fierce_wolf/go-fox-edge-common/commUtil/periodTask"
)

var (
	deviceSubscribe *deviceSubscribeScheduler
	deviceValuePush *deviceValuePushScheduler
)

func init() {
	deviceSubscribe = &deviceSubscribeScheduler{}
	deviceValuePush = &deviceValuePushScheduler{}
}

func Scheduler() {
	go deviceSubscribe.scheduler()
	go deviceValuePush.scheduler()
	
	periodTask.InsertTask(commMqtt.AutoTask)
}
